🎖️GitЯра🎖️
Node / meshtastic / Meshtastic-Android / files / core / data / src / commonTest / kotlin / org / meshtastic / core / data / manager / MeshMessageProcessorImplTest.kt
Displaying Raw • Download
core/data/src/commonTest/kotlin/org/meshtastic/core/data/manager/MeshMessageProcessorImplTest.kt e85300531e124df08788c1b765d50af1bf6d516d (e8530053) Text, 12.71 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.data.manager
Tff7b72import T7ee787dev.mokkery.MockMode
Tff7b72import T7ee787dev.mokkery.answering.returns
Tff7b72import T7ee787dev.mokkery.every
Tff7b72import T7ee787dev.mokkery.matcher.any
Tff7b72import T7ee787dev.mokkery.mock
Tff7b72import T7ee787dev.mokkery.verify
Tff7b72import T7ee787dev.mokkery.verifySuspend
Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope
Tff7b72import T7ee787kotlinx.coroutines.ExperimentalCoroutinesApi
Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow
Tff7b72import T7ee787kotlinx.coroutines.test.UnconfinedTestDispatcher
Tff7b72import T7ee787kotlinx.coroutines.test.advanceUntilIdle
Tff7b72import T7ee787kotlinx.coroutines.test.runTest
Tff7b72import T7ee787okio.ByteString
Tff7b72import T7ee787org.meshtastic.core.repository.FromRadioPacketHandler
Tff7b72import T7ee787org.meshtastic.core.repository.MeshDataHandler
Tff7b72import T7ee787org.meshtastic.core.repository.MeshLogRepository
Tff7b72import T7ee787org.meshtastic.core.repository.MeshRouter
Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager
Tff7b72import T7ee787org.meshtastic.core.repository.ServiceRepository
Tff7b72import T7ee787org.meshtastic.proto.Data
Tff7b72import T7ee787org.meshtastic.proto.FromRadio
Tff7b72import T7ee787org.meshtastic.proto.LogRecord
Tff7b72import T7ee787org.meshtastic.proto.MeshPacket
Tff7b72import T7ee787org.meshtastic.proto.PortNum
Tff7b72import T7ee787kotlin.test.BeforeTest
Tff7b72import T7ee787kotlin.test.Test
Tf0883e@OptInTb4b4b4(Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4)
Tff7b72class T56d364MeshMessageProcessorImplTest Tb4b4b4{
Tff7b72private Tff7b72val Te6edf3nodeManager Tff7b72= Te6edf3mockTff7b72<Te6edf3NodeManagerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3serviceRepository Tff7b72= Te6edf3mockTff7b72<Te6edf3ServiceRepositoryTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3meshLogRepository Tff7b72= Te6edf3mockTff7b72<Te6edf3MeshLogRepositoryTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3router Tff7b72= Te6edf3mockTff7b72<Te6edf3MeshRouterTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3fromRadioDispatcher Tff7b72= Te6edf3mockTff7b72<Te6edf3FromRadioPacketHandlerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3dataHandler Tff7b72= Te6edf3mockTff7b72<Te6edf3MeshDataHandlerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3testDispatcher Tff7b72= Te6edf3UnconfinedTestDispatcherTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3processorTb4b4b4: Te6edf3MeshMessageProcessorImpl
Tff7b72private Tff7b72val Te6edf3myNodeNum Tff7b72= T79c0ff1T79c0ff2T79c0ff3T79c0ff4T79c0ff5
Tff7b72private Tff7b72val Te6edf3isNodeDbReady Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Tff7b72falseTb4b4b4)
Tf0883e@BeforeTest
Tff7b72fun Td2a8ffsetUpTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3isNodeDbReady Tb4b4b4} Te6edf3returns Te6edf3isNodeDbReady
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNum Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTff7b72<Tffa657Int?Tff7b72>Tb4b4b4(Te6edf3myNodeNumTb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3routerTb4b4b4.Te6edf3dataHandler Tb4b4b4} Te6edf3returns Te6edf3dataHandler
Tb4b4b4}
Tff7b72private Tff7b72fun Td2a8ffcreateProcessorTb4b4b4(Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4)Tb4b4b4: Te6edf3MeshMessageProcessorImpl Tff7b72= Te6edf3MeshMessageProcessorImplTb4b4b4(
Te6edf3nodeManager Tff7b72= Te6edf3nodeManagerTb4b4b4,
Te6edf3serviceRepository Tff7b72= Te6edf3serviceRepositoryTb4b4b4,
Te6edf3meshLogRepository Tff7b72= Te6edf3lazy Tb4b4b4{ Te6edf3meshLogRepository Tb4b4b4}Tb4b4b4,
Te6edf3router Tff7b72= Te6edf3lazy Tb4b4b4{ Te6edf3router Tb4b4b4}Tb4b4b4,
Te6edf3fromRadioDispatcher Tff7b72= Te6edf3fromRadioDispatcherTb4b4b4,
Te6edf3scope Tff7b72= Te6edf3scopeTb4b4b4,
Tb4b4b4)
T8b949e// ---------- handleFromRadio: non-packet variants ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`handleFromRadio dispatches non-packet variants to fromRadioDispatcher`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Tff7b72val Te6edf3logRecord Tff7b72= Te6edf3LogRecordTb4b4b4(Te6edf3message Tff7b72= Ta5d6ff"Ta5d6fftest logTa5d6ff"Tb4b4b4)
Tff7b72val Te6edf3fromRadio Tff7b72= Te6edf3FromRadioTb4b4b4(Te6edf3log_record Tff7b72= Te6edf3logRecordTb4b4b4)
Tff7b72val Te6edf3bytes Tff7b72= Te6edf3FromRadioTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3encodeTb4b4b4(Te6edf3fromRadioTb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3bytesTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3fromRadioDispatcherTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleFromRadio falls back to LogRecord parsing when FromRadio fails`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
T8b949e// Encode a raw LogRecord (not wrapped in FromRadio) — first decode as FromRadio fails,
T8b949e// fallback decode as LogRecord succeeds
Tff7b72val Te6edf3logRecord Tff7b72= Te6edf3LogRecordTb4b4b4(Te6edf3message Tff7b72= Ta5d6ff"Ta5d6fffallback logTa5d6ff"Tb4b4b4)
Tff7b72val Te6edf3bytes Tff7b72= Te6edf3LogRecordTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3encodeTb4b4b4(Te6edf3logRecordTb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3bytesTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Should have been dispatched as a FromRadio with log_record set
Te6edf3verify Tb4b4b4{ Te6edf3fromRadioDispatcherTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleFromRadio with completely invalid bytes does not crash`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
T8b949e// Invalid protobuf bytes — both parses should fail
Tff7b72val Te6edf3garbage Tff7b72= Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3xFFTb4b4b4.Te6edf3toByteTb4b4b4(Tb4b4b4)Tb4b4b4, T79c0ff0Te6edf3xFETb4b4b4.Te6edf3toByteTb4b4b4(Tb4b4b4)Tb4b4b4, T79c0ff0Te6edf3xFDTb4b4b4.Te6edf3toByteTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3garbageTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// No crash
Tb4b4b4}
T8b949e// ---------- handleReceivedMeshPacket: early buffering ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`packets are buffered when node DB is not ready`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72false
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= T79c0ff1Tb4b4b4,
Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Packet should be buffered, not processed
T8b949e// (no emitMeshPacket call since DB is not ready)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`buffered packets are flushed when node DB becomes ready`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72false
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= T79c0ff1Tb4b4b4,
Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Now make DB ready
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Buffered packet should have been flushed and processed
Te6edf3verifySuspend Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3emitMeshPacketTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`early buffer overflow drops oldest packet`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72false
T8b949e// The maxEarlyPacketBuffer is 10240 — we won't actually fill it in this test,
T8b949e// but we test the boundary behavior conceptually. Instead, test that multiple
T8b949e// packets are accumulated properly.
Te6edf3repeatTb4b4b4(T79c0ff5Tb4b4b4) Tb4b4b4{ Te6edf3i Tff7b72-Tff7b72>
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= Te6edf3iTb4b4b4,
Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0 Tff7b72+ Te6edf3iTb4b4b4,
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Tb4b4b4}
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Flush
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// All 5 packets should have been processed
Te6edf3verifySuspend Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3emitMeshPacketTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- handleReceivedMeshPacket: rx_time normalization ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`packets with rx_time 0 get current time`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= T79c0ff1Tb4b4b4,
Te6edf3from Tff7b72= Te6edf3myNodeNumTb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff0Tb4b4b4, T8b949e// should be replaced with current time
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifySuspend Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3emitMeshPacketTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`packets with non-zero rx_time keep their time`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= T79c0ff2Tb4b4b4,
Te6edf3from Tff7b72= Te6edf3myNodeNumTb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff1T79c0ff7T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifySuspend Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3emitMeshPacketTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- handleReceivedMeshPacket: node updates ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`processReceivedMeshPacket updates myNode lastHeard`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= T79c0ff1T79c0ff0Tb4b4b4,
Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff1T79c0ff7T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Should have called updateNode for myNodeNum (lastHeard update)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3updateNodeTb4b4b4(Te6edf3myNodeNumTb4b4b4, Te6edf3withBroadcast Tff7b72= Tff7b72trueTb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`processReceivedMeshPacket updates sender node`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Tff7b72val Te6edf3senderNode Tff7b72= T79c0ff9T79c0ff9T79c0ff9
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= T79c0ff1T79c0ff0Tb4b4b4,
Te6edf3from Tff7b72= Te6edf3senderNodeTb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff1T79c0ff7T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Te6edf3channel Tff7b72= T79c0ff1Tb4b4b4,
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Should have called updateNode for the sender
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3updateNodeTb4b4b4(Te6edf3senderNodeTb4b4b4, Te6edf3withBroadcast Tff7b72= Tff7b72falseTb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- handleReceivedMeshPacket: null decoded ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`packet with null decoded is skipped`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Tff7b72val Te6edf3packet Tff7b72= Te6edf3MeshPacketTb4b4b4(Te6edf3id Tff7b72= T79c0ff1Tb4b4b4, Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4, Te6edf3decoded Tff7b72= Tff7b72nullTb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// No crash, no emitMeshPacket call (decoded is null so processReceivedMeshPacket returns early)
Tb4b4b4}
T8b949e// ---------- handleReceivedMeshPacket: null myNodeNum ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`processReceivedMeshPacket with null myNodeNum skips node updates`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= T79c0ff1T79c0ff0Tb4b4b4,
Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff1T79c0ff7T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Tff7b72nullTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// emitMeshPacket should still be called, but node updates should be skipped
Te6edf3verifySuspend Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3emitMeshPacketTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- clearEarlyPackets ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`clearEarlyPackets empties the buffer`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72false
Tff7b72val Te6edf3packet Tff7b72=
Te6edf3MeshPacketTb4b4b4(
Te6edf3id Tff7b72= T79c0ff1Tb4b4b4,
Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4,
Te6edf3decoded Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)Tb4b4b4,
Te6edf3rx_time Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3clearEarlyPacketsTb4b4b4(Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Now make DB ready — the buffer should be empty, nothing to flush
Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72= Tff7b72true
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// emitMeshPacket should NOT have been called (buffer was cleared)
Tb4b4b4}
T8b949e// ---------- logVariant ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`FromRadio log_record variant is logged as MeshLog`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3processor Tff7b72= Te6edf3createProcessorTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Tff7b72val Te6edf3logRecord Tff7b72= Te6edf3LogRecordTb4b4b4(Te6edf3message Tff7b72= Ta5d6ff"Ta5d6ffdevice logTa5d6ff"Tb4b4b4)
Tff7b72val Te6edf3fromRadio Tff7b72= Te6edf3FromRadioTb4b4b4(Te6edf3log_record Tff7b72= Te6edf3logRecordTb4b4b4)
Tff7b72val Te6edf3bytes Tff7b72= Te6edf3FromRadioTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3encodeTb4b4b4(Te6edf3fromRadioTb4b4b4)
Te6edf3processorTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3bytesTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifySuspend Tb4b4b4{ Te6edf3meshLogRepositoryTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Served by rngit 1.5.0 - Generated in 0.09s